import asyncio
import random

async def producer(queue):
    while True:
        # 模拟生产新任务
        new_task = f"Task {random.randint(0, 10)}"
        print(f"生产新任务： {new_task}")
        await queue.put(new_task)
        # 模拟一些延迟
        await asyncio.sleep(3)

async def consumer(queue):
    while True:
        # 等待获取新任务
        task = await queue.get()
        print(f"获取到任务: {task}")
        # 模拟处理任务的耗时操作
        await asyncio.sleep(10)

async def main():
    # 创建异步队列
    queue = asyncio.Queue()
    # 启动生产者和消费者任务
    await asyncio.gather(
        producer(queue),
        consumer(queue)
    )

# 启动主事件循环
asyncio.run(main())
